package com.itbupt.domain.task.repository;

import com.itbupt.domain.task.model.entity.TaskEntity;

import java.util.List;

/**
 * @Author dingchang
 * @Date 2025/4/7 15:12
 * @Description: 任务服务仓储接口
 */
public interface ITaskRepository {

    // 查询发送MQ失败和超时1分钟未发送的MQ
    List<TaskEntity> queryNoSendMessageTaskList();

    // 发送任务消息
    void sendMessage(TaskEntity taskEntity);

    // 更新任务发送消息成功
    void updateTaskSendMessageCompleted(String userId, String messageId);

    // 更新任务发送消息失败
    void updateTaskSendMessageFail(String userId, String messageId);

}
